# -*- coding: utf-8 -*-
from datetime import timedelta
from utils.operators.bash import BashOperator

from spmi.time_sensor import time_after_05_00

spmi_ods__spmn_tran_oper_msg_err_log = BashOperator(
    task_id='spmi_ods__spmn_tran_oper_msg_err_log',
    execution_timeout=timedelta(hours=3),
    email=['yl_etl@yl-scm.com','yl_bigdata@yl-scm.com'],
    bash_command="spmi/ods/mysql/spmi/spmn_tran_oper_msg_err_log/execute.sh",
    pool='spmi_06',
    pool_slots=4,
)

spmi_ods__spmn_tran_oper_msg_err_log << time_after_05_00